

TOPIC_SENDER_OUTPUT = []

def topicsender(func):
    def wrapper(*args, **kwargs):
        # start_time = time.time()
        try:
            topic, data = func(*args, **kwargs)
        except Exception as e:
            print(f"error send topic, func: {str(func)}, error: {str(e)}")
        TOPIC_SENDER_OUTPUT.append((topic,data))
        print(f"[topic-add] topic:{topic}, data:{data}")
    return wrapper

def send_topic_data():
    pass

